package com.ning.parking.service.impl;

import com.ning.parking.domain.ParkingLotBaseInfo;

import java.util.concurrent.LinkedBlockingQueue;

public class RocketMQProducer {
    public LinkedBlockingQueue<String> QUEUE = new LinkedBlockingQueue<>();
    public void sendAsync(String drivewayInfo, ParkingLotBaseInfo selectByParentParkingLotId) {
        QUEUE.add(drivewayInfo);
    }
}
